var express = require('express');
var expressWs = require("express-ws");
var router = express.Router();
// let electronMongs = require('../mongodb/mongo')

expressWs(router);  //将 express 实例上绑定 websocket 的一些方法
// 添加新增
// router.post('/saveUsb', function (req, res) {
//     var obj = req.body
//     usbadmi.create(obj, function (err, result) {
//         if (!err) {
//             res.send(result);
//         }
//     })
// })
let connections = [];
router.ws("/user", function (ws, req) {
  // ws.send("你连接成功了");
  connections.push(ws);
  ws.on("message", function (msg) {
    // ws.send(msg);  //单个
    connections.forEach((e) => {
      e.send(msg)    //所有
    })
  });

})


// router.post('/biaoList', function (req, res) {
//     console.log(req)
//     var obj = req.body
//     electronMongs.find(obj, function (err, result) {
//         if (!err) {
//             res.send(result);
//         }
//     })
// })

// // 获取版
// router.post('/obtainUsbList', async function (req, res) {
//     // console.log(req)
//     var obj = req.body
//     let page = obj.startPage
//     let limts = obj.limit
//     // var query = {};
//     // ` if (obj.usbType) {
//     //         query.usbType = obj.usbType
//     //     }
//     //     if (obj.legal) {
//     //         query.legal = obj.legal
//     //     }`
//     for (let i in obj) {
//         let val = new RegExp(obj[i])
//         obj[i] = val
//     }
//     let result = await usbadmi.find(obj).skip(page).limit(limts)
//     res.send(result);
// })


// // 修改
// router.post('/uspdataUsb', function (req, res) {
//     console.log(req)
//     var obj = req.body
//     usbadmi.findOneAndUpdate({ _id: obj._id }, obj, function (err, result) {
//         if (!err) {
//             res.send(result)
//         }
//     })
// })

// // 删除
// router.post('/deleteUsb', function (req, res) {
//     var obj = req.body
//     console.log(obj)
//     for (let i = 0; i < obj.length; i++) {
//         usbadmi.deleteOne({ _id: obj[i] }, function (err, result) {
//             if (!err) {
//                 res.send(result)
//             }
//         })
//     }

// })

module.exports = router